# -*- coding: utf-8 -*-
from datetime import timedelta
from time import time
from airflow.operators.bash import BashOperator
from jms.dm.dm_network_whole_massage import jms_dm__dm_network_whole_massage

tidb_jms_dwm__dwm_network_whole_massage = BashOperator(
    pool='unlimited_pool',
    task_id="tidb_jms_dwm__dwm_network_whole_massage",
    bash_command='jms/doris/tidb/dwm_network_whole_massage/execute.sh',
    execution_timeout=timedelta(minutes=15),
    #邮箱更换
    email=['rongguangfan@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=2,
)

tidb_jms_dwm__dwm_network_whole_massage << jms_dm__dm_network_whole_massage